package com.david.mydemo.ctl_kafka.config;

public class KafkaConfig {

    /**
     * kafka消费者分组
     */
    public static final String GROUP_ID = "test-consumer-group";

    /**
     * kafka主题
     */
    public static final String TOPICS = "order_state_change";
//    public static final String TOPICS = "test-topic";

    /**
     * kafka分区
     */
    public static final int PARTION = 10;

    /**
     * kafka消息key
     */
    public static final String MESSAGE_KEY = "test-msg";

}
